package com.zshy.base.mq.store;

import com.zshy.base.mq.core.MQEvent;

/**
 * 消息持久化
 *
 * @author zhouhengzhe
 */
public interface MQEventStorer<T extends MQEvent> {

    /**
     * 消息持久化
     *
     * @param mqEvent 消息
     */
    void store(T mqEvent);
}